package com.vcg.community.filter; /**
 * 产生记录处理器的工厂
 * @author felayman
 * @since 16/1/5
 */
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessor;
import com.amazonaws.services.kinesis.clientlibrary.interfaces.IRecordProcessorFactory;

public class StreamsRecordProcessorFactory implements IRecordProcessorFactory {


    public IRecordProcessor createProcessor() {
        return new StreamsRecordProcessor();
    }

}
